package cn.doitedu.hbase.bulkloader

import org.apache.spark.sql.SparkSession

object MovieRating {

  def main(args: Array[String]): Unit = {


    val spark = SparkSession.builder().appName("").master("local").getOrCreate()


    val json = spark.read.json("E:\\mrdata\\json\\input\\rating.json")


    json.show(10,false)


    spark.close()




  }


}
